package produce.config;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

public interface MySource {

    /**
     * 注意，这里的名字要和我们配置文件中的 spring.cloud.stream.bindings 配置项对应上
     * @Output 注解的方法的返回结果为 MessageChannel 类型，可以使用它发送消息。
     * @return
     */

    @Output("cluster-output")
    MessageChannel clusterOutput();

    @Output("radio-output")
    MessageChannel radioOutput();

    @Output("retry-output")
    MessageChannel retryOutput();

    @Output("order-output")
    MessageChannel orderOutput();

    @Output("filter-output")
    MessageChannel filterOutput();

    @Output("transactional-output")
    MessageChannel transactionalOutput();

}